62221c0d14ae3abe7672cb13c7b8a76122fe806a,workflow/src/test/java/io/rouz/task/TaskEvalBehaviorTest.java,TaskEvalBehaviorTest,shouldEvaluateInputsInParallelForCurriedTask,#,408
Before Change
@Test
public void shouldEvaluateInputsInParallelForCurriedTask() throws Exception {
AtomicBoolean processed = new AtomicBoolean(false);
Task<String> task = Task.named("WithInputs").<String>curryTo()
.in(() -> leaf("A"))
.in(() -> leaf("B"))
.in(() -> leaf("C"))
.process(c -> b -> a -> {
After Change
@Test
public void shouldEvaluateInputsInParallelForCurriedTask() throws Exception {
AtomicBoolean processed = new AtomicBoolean(false);
Task<String> task = Task.ofType(String.class).named("WithInputs").curried()
.in(() -> leaf("A"))
.in(() -> leaf("B"))
.in(() -> leaf("C"))
.process(c -> b -> a -> {